﻿using System;
using System.Collections.Generic;
using System.Configuration;
using System.Data;
using System.Data.SqlClient;
using System.Linq;
using System.Text;
using System.Threading.Tasks;

namespace DreamCMS.WebCore.Data
{
    /// <summary>
    /// 创建人：崔永键
    /// 创建时间：2013-08-14
    /// 说明：数据库助手类. 负责根据用户的需求来执行查询
    /// 版权：www.cuiyongjian.com
    /// </summary>
    public class SqlServerHelper
    {
        #region 初始化数据库连接字符串字段
        /// <summary>
        /// 使用web.config中定义的的连接字符串来.构造基于web.config设置的连接字符串的的SqlHelper
        /// </summary>
        private readonly static string connStr = ConfigurationManager.ConnectionStrings["sqlServerRealConnStr"].ConnectionString;
        #endregion

        #region 创建SqlCommand对象供内部方法使用
        private static SqlCommand MakeCommand(SqlConnection conn, CommandType cmdType, string cmdText, SqlParameter[] paras)
        {
            if (conn.State == ConnectionState.Closed)
            {
                try
                {
                    conn.Open();
                }
                catch (Exception ex)
                {
                    throw ex;
                }
            }
            SqlCommand cmd = conn.CreateCommand();
            cmd.CommandText = cmdText;
            cmd.CommandType = cmdType;
            if (paras != null)
            {
                cmd.Parameters.AddRange(paras);
            }
            return cmd;
        }
        #endregion

        #region ExecuteScalar执行查询返回结果集的第一行第一列（一般用在统计单个结果时的查询）
        /// <summary>
        /// 执行查询返回结果集的第一行第一列（一般用在统计单个结果时的查询）
        /// </summary>
        /// <param name="cmdType">命令类型</param>
        /// <param name="cmdText">命令文本</param>
        /// <returns></returns>
        public static object ExecuteScalar(CommandType cmdType, string cmdText)
        {
            return SqlServerHelper.ExecuteScalar(cmdType, cmdText, null);
        }
        /// <summary>
        /// 执行查询返回结果集的第一行第一列（一般用在统计单个结果时的查询）
        /// </summary>
        /// <param name="cmdType">命令类型</param>
        /// <param name="cmdText">命令文本</param>
        /// <param name="paras">参数集合</param>
        /// <returns></returns>
        public static object ExecuteScalar(CommandType cmdType, string cmdText, SqlParameter[] paras)
        {
            object rel = null;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                using (SqlCommand cmd = MakeCommand(conn, cmdType, cmdText, paras))
                {
                    rel = cmd.ExecuteScalar();
                    cmd.Parameters.Clear();
                }
            }
            return rel;
        }
        #endregion

        #region ExecuteNonQuery查询，返回受影响行数
        /// <summary>
        /// 该方法执行传入的"增"，"删"，"改" SQL语句（(如果您的sql语句中有参数，请使用带参数的重载来避免SQL注入）
        /// </summary>
        /// <param name="cmdType">命令类型</param>
        /// <param name="cmdText">一个"添加"或"删除"或"更新"的SQL语句，或者一个存储过程名称</param>

        /// <returns>返回受影响的记录数</returns>
        public static int ExecuteNonQuery(CommandType cmdType, string cmdText)
        {
            int rel = SqlServerHelper.ExecuteNonQuery(cmdType, cmdText, null);
            return rel;
        }

        /// <summary>
        /// 执行带参数的SQL“增加”“删除”“修改”语句。
        /// </summary>
        /// <param name="cmdType">命令类型---sql语句还是存储过程类型</param>
        /// <param name="cmdText">SQL语句或者存储过程</param>
        /// <param name="paras">参数集合</param>
        /// <returns>返回受影响的行数</returns>
        public static int ExecuteNonQuery(CommandType cmdType, string cmdText, SqlParameter[] paras)
        {
            int rel = 0;
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                using (SqlCommand cmd = MakeCommand(conn, cmdType, cmdText, paras))
                {
                    rel = cmd.ExecuteNonQuery();
                    cmd.Parameters.Clear();
                }
            }
            return rel;
        }
        #endregion

        #region ExecuteQuery执行查询，返回DataTable数据
        /// <summary>
        /// 执行传入的select查询SQL语句(如果您的sql语句中有参数，请使用带参数的重载来避免SQL注入)
        /// </summary>
        /// <param name="cmdType">命令类型--是SQLText还是存储过程</param>
        /// <param name="cmdText">命令文本---可以是Sql语句或者存储过程名称</param>
        /// <returns>返回查询的结果集DataTable</returns>
        public static DataTable ExecuteDataTable(CommandType cmdType, string cmdText)
        {
            DataTable dt = SqlServerHelper.ExecuteDataTable(cmdType, cmdText, null);
            return dt;
        }

        ///<summary>
        /// 带参数的ExecuteQuery查询
        /// </summary>
        /// <param name="cmdType">命令类型--是SQLTEXT还是存储过程</param>
        /// <param name="cmdText">命令文本</param>
        /// <param name="paras">参数集合</param>

        /// <returns>返回查询结果DataTable</returns>
        public static DataTable ExecuteDataTable(CommandType cmdType, string cmdText, SqlParameter[] paras)
        {
            DataTable dt = new DataTable();
            using (SqlConnection conn = new SqlConnection(connStr))
            {
                using (SqlCommand cmd = MakeCommand(conn, cmdType, cmdText, paras))
                {
                    using (SqlDataReader dr = cmd.ExecuteReader())
                    {
                        dt.Load(dr);
                    }
                    cmd.Parameters.Clear();
                }
            }
            return dt;
        }
        #endregion

    }
}

